package com.guojizhuang.parititioner;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;


public class MonthPartitioner extends Partitioner<Text, Text> {
    @Override
    public int getPartition(Text text, Text text2, int i) {
        String[] texts = text2.toString().split(",");
        if (texts.length > 3 && texts[3].length() >= 6) {
            return Integer.parseInt(texts[3].substring(4, 6)) % 7;
        } else {
            // 如果字符串长度不足，可以返回一个默认的分区值或者抛出异常
            return 0; // 或者 throw new IllegalArgumentException("Invalid input: " + text2.toString());
        }
    }
}
